package com.flink.ttest.cofig;

import com.alibaba.fastjson.JSON;
import org.apache.flink.api.common.functions.MapFunction;

/**
 * @author: LCG
 * @date: 2022-06-28 13:28:59
 * @description:
 **/
public class MyMapFunction implements MapFunction<String,Order> {

    @Override
    public Order map(String json) throws Exception {

        System.out.println("============>"+json);

        Order order = JSON.parseObject(json, Order.class);

        return order;
    }
}
